from celery import Celery

# 1. 初始化Celery应用对象
app = Celery("luffy")

#1.1 如果celery需要在任务调用其它框架的内部对象，则需要进行相应的框架初始化
import os
import django
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'luffyapi.settings.dev')
django.setup()

# 2. 加载初始化配置
app.config_from_object("mycelery.config")

# 3. 注册异步任务
# app.autodiscover_tasks(["任务组1","任务组2",....])
app.autodiscover_tasks(["mycelery.sms",])

# 4. 在终端启动Celery
# celery -A mycelery.main worker -l info
# win10下需要采用协程来运行
# pip install eventlet
# celery -A mycelery.main worker -l info -P eventlet